f669aa9e2d36c2f256cbb46adc8f4a96caf0c941,src/main/java/org/influxdb/impl/InfluxDBImpl.java,InfluxDBImpl,write,#BatchPoints#,143
Before Change
@Override
public void write(final BatchPoints batchPoints) {
this.batchedCount.addAndGet(batchPoints.getPoints().size());
TypedString lineProtocol = new TypedString(batchPoints.lineProtocol());
this.influxDBService.writePoints(
this.username,
this.password,
batchPoints.getDatabase(),
batchPoints.getRetentionPolicy(),
TimeUtil.toTimePrecision(TimeUnit.NANOSECONDS),
batchPoints.getConsistency().value(),
lineProtocol);
}
After Change
@Override
public void write(final BatchPoints batchPoints) {
this.batchedCount.addAndGet(batchPoints.getPoints().size());
RequestBody lineProtocol = RequestBody.create(MEDIA_TYPE_STRING, batchPoints.lineProtocol());
execute(this.influxDBService.writePoints(
this.username,
this.password,
batchPoints.getDatabase(),
batchPoints.getRetentionPolicy(),
TimeUtil.toTimePrecision(TimeUnit.NANOSECONDS),
batchPoints.getConsistency().value(),
lineProtocol));
}
@Override